from funcs import *
期货前缀ss = get_期货前缀ss(False)
df_所有合约 = get_df_所有合约()
code_delist_date_dict = get_code_delist_date_dict(df_所有合约)

from concurrent.futures import ProcessPoolExecutor
from tqdm import tqdm

# 假设 get_ddd 是您的函数，期货前缀ss 是一个包含多个期货前缀的列表

def process_task(期货前缀):
    return get_ddd(期货前缀, code_delist_date_dict)

# 使用 ProcessPoolExecutor 来并行处理
with ProcessPoolExecutor() as executor:
    # 使用 map 函数以并行方式执行
    results = list(tqdm(executor.map(process_task, 期货前缀ss), total=len(期货前缀ss)))